package com.example.concurrency.queue.thread;

import java.util.concurrent.BlockingQueue;

/**
 * <p>
 *  消费者
 * </p>
 *
 * @author Ashe
 * @version V1.2.0
 * @date 2019年08月20日 19:51
 * @modificationHistory=========================逻辑或功能性重大变更记录
 * @modify By: {修改人} 2019年08月20日
 * @modify reason: {方法名}:{原因}
 * ...
 */
public class Consumer implements Runnable {

    protected BlockingQueue queue;

    public Consumer(BlockingQueue queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        try {
            System.out.println(queue.take());
            System.out.println(queue.take());
            System.out.println(queue.take());
        } catch (Throwable e) {
            e.printStackTrace();
        }
    }
}

